#!/bin/sh
#################################################
###  功能说明:原始数据导入
###  导入方式:全量导入
###  导入结果:hive中raw库
###  运行频率:初始化
###  数据来源:河南交职—人事-教职工
###  运行条件:无,支持数据重跑
###  运行命令:sh job_name.sh
###  维护人:马虎山
###  运行日期：2018-10-17
#################################################
HIVE_DB=raw
TABLE_PREFIX='hr_'
if [ $# == 1 ]
    then
    echo "table:$1"
    tables=($1)
else
    tables=('
T_JZG
T_ZG_JSCDPXB
T_ZG_LSJYQK
')
fi

for ele in ${tables[*]}
do
    table=${ele}

    #删除外部文件
    hadoop fs -rm -r "hdfs:/${HIVE_DB}/${TABLE_PREFIX}${table}"
    #删除表结构
    hive -e "USE ${HIVE_DB};DROP TABLE IF EXISTS ${TABLE_PREFIX}${table};"
    #新建表
   sqoop create-hive-table --connect jdbc:oracle:thin:@172.16.98.27:1521/KFPTDB --username usr_zg --password sxny@123 \
     --table USR_ZSJ.${table}  --hive-table ${HIVE_DB}.${TABLE_PREFIX}${table}
    #改为外部表
    hive -e "alter table ${HIVE_DB}.${TABLE_PREFIX}${table} set TBLPROPERTIES ('EXTERNAL'='TRUE');"
    #修改外部表路径
    hive -e "alter table ${HIVE_DB}.${TABLE_PREFIX}${table} set location 'hdfs:/${HIVE_DB}/${TABLE_PREFIX}${table}';"
    #导入数据
     sqoop import --hive-import --connect jdbc:oracle:thin:@172.16.98.27:1521/KFPTDB --username usr_zg --password sxny@123 \
    --table USR_ZSJ.${table} --hive-table ${HIVE_DB}.${TABLE_PREFIX}${table} \
    -m 1 --hive-overwrite \
    --input-null-string '\\N' \
    --input-null-non-string '\\N' \
    --hive-drop-import-delims \
    --null-string '\\N' --null-non-string '\\N' --fields-terminated-by '\0001'
done

rm -rf ./*.java